# 1-导包
import pymysql

# 2-创建连接，获取连接对象
conn = pymysql.connect(host="211.103.136.244",user="student",password="KDTX_student_202304",
                       port=7068,database="huike",charset='utf8')
# 3-通过连接对象获取游标
cur = conn.cursor()

try:  # 执行可能出现异常的代码
    # 4-通过游标执行SQL
    cur.execute('delete from tb_contract where contract_no = "3222";')
    # 如果执行正常，还需要提交事务才能成功
    conn.commit()
except Exception as e:
    # 如果出现异常，执行回滚操作
    conn.rollback()
    # 打印异常日志
    print(e)
finally:  # 不管执行结果如何，都要进行关闭资源操作
    # 5-关闭游标
    cur.close()
    # 6-关闭连接
    conn.close()